package com.clj.rocketmq_example.mq;

import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
import org.apache.rocketmq.common.message.MessageExt;

import com.clj.rocketmq_example.enums.MqAction;

/**
 * 有顺序消息监听
 * @author C117
 *
 */
public interface  MessageOrderListener {
	 /**
     * mq 消费接口
     * @param var1
     * @param context
     * @return
     */
    MqAction consume(MessageExt var1, ConsumeOrderlyContext context);
}
